50b490e046bdc23b23fbb268400abcc41a0de72c,src/java/org/apache/cassandra/service/ReadCallback.java,ReadCallback,response,#Message#,129
Before Change
public void response(Message message)
{
resolver.preprocess(message);
int n = waitingFor(message)
? received.incrementAndGet()
: received.get();
After Change
return blockfor == 1 ? resolver.getData() : resolver.resolve();
}
public void response(Message message)
{
ReadResponse result = resolver.preprocess(message);
int n = waitingFor(result, message.getFrom())
? received.incrementAndGet()
: received.get();